package com.shujia.tf;

import com.alibaba.fastjson.JSON;
import com.shujia.bean.Car;
import org.apache.flink.api.common.functions.MapFunction;

public class CarMapper implements MapFunction<String, Car> {
    @Override
    public Car map(String value) throws Exception {
        return JSON.parseObject(value, Car.class);
    }
}
